package com.cpic.rxjava;

public interface Emitter<T> {
    void onNext(T t);
    void onError(Throwable throwable);
//    void onSubcribe();
    void onComplete();
}
